package com.wudl.core

import org.apache.spark.rdd.RDD
import org.apache.spark.{SparkConf, SparkContext}

object SparkArray {
  def main(args: Array[String]): Unit = {

    val conf: SparkConf = new SparkConf().setMaster("local[1]").setAppName("SparkArray")
    val sc: SparkContext = new SparkContext(conf);
    val rdd:RDD[Int] = sc.parallelize(Array(1,2,3,4,5,6))
    rdd.foreach(println)

    sc.stop()



  }

}
